package com.etl.dataflow.executor.entity;

import com.etl.dataflow.common.entity.TaskInfo;
import com.etl.dataflow.executor.core.AbstractAfterReadInterceptor;
import com.etl.dataflow.executor.core.AbstractAfterWriteInterceptor;
import com.etl.dataflow.executor.core.AbstractTaskLaunchInterceptor;
import lombok.Data;
import lombok.EqualsAndHashCode;

/**
 * 任务信息的扩展
 *
 * @author dx
 */
@EqualsAndHashCode(callSuper = true)
@Data
public class ExecutorTaskInfo extends TaskInfo {
    /**
     * 任务启动前拦截器
     */
    private AbstractTaskLaunchInterceptor taskLaunchInterceptor;

    /**
     * 读后拦截器
     */
    private AbstractAfterReadInterceptor afterReadInterceptor;

    /**
     * 写后拦截器
     */
    private AbstractAfterWriteInterceptor afterWriteInterceptor;
}
